package com.xzx.flink.tableapi;

import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.TableEnvironment;

/**
 * @version 1.0
 * @auther xinzhixuan
 * @date 2022/5/21 17:47
 */
public class TableAPI_02_Env {
    public static void main(String[] args) throws Exception {
        EnvironmentSettings environmentSettings = EnvironmentSettings.newInstance()
                .inStreamingMode()// 流模式
                .withBuiltInCatalogName("")// 指定catalog
                .withBuiltInDatabaseName("")// 指定database
                .build();
        TableEnvironment tableEnvironment = TableEnvironment.create(environmentSettings);
        tableEnvironment.useCatalog("");
        tableEnvironment.useDatabase("");

    }
}
